package com.demo.kafka.constants;

/**
 * 常量
 * @author cyj
 **/
public class KafkaConstants {

    /**
     * 代理的topic
     */
    public static final String PROXY_TOPIC = "proxy_topic";

    public static String getDelayTopic(int num) {
        return PROXY_TOPIC + "_" + num;
    }
}
